package com.example.mymessagequeue.common;

import com.example.mymessagequeue.mqserver.core.BasicProperties;

import java.io.IOException;

/**
 * 单纯的函数式接口(回调函数). 收到消息之后要处理消息时调用的方法.
 */
@FunctionalInterface
public interface Consumer {

    /**
     * Deliver 的意思是 "投递" 这个方法预期是在每次服务器收到消息之后来调用
     * 通过这个方法把消息推送给对应的消费者
     */
    void handleDelivery(String consumerTag, BasicProperties basicProperties, byte[] body) throws MqException, IOException;
}
